package com.aliyun.messagemgt.application.service.mq;


import com.aliyun.openservices.ons.api.SendResult;

import java.io.IOException;
import java.util.List;
import java.util.Map;

/**
 * @Author: zhangbixing
 * @Date: 2019/1/31 16:02
 * @description:
 */
public interface MessageQueenService {
    /**
     * 发送MQ消息
     *
     * @param obj
     * @param tag
     * @return
     * @throws IOException
     */
    public SendResult sendMessage(Map<String, Object> obj, String tag) throws IOException;

    /**
     * 发送MQ消息
     *
     * @param obj
     * @param tag
     */
    void sendMessage(Object obj, String tag);

    /**
     * 发送MQ消息  为list参数
     *
     * @param objs
     * @param tag
     */
    void sendMessageList(List objs, String tag);
}
